// 创建一个包含5个元素的RDD，每个元素都是一个二元组，第一个元素是字符串类型的名字，第二个元素是Int类型的分数

import org.apache.spark.{SparkConf, SparkContext}

object RDDExample {
  def main(args: Array[String]): Unit = {
    // 创建SparkConf对象和SparkContext对象
    val conf = new SparkConf().setAppName("RDDExample").setMaster("local")
    val sc = new SparkContext(conf)
    
    // 创建包含5个元素的RDD
    val rdd = sc.parallelize(Seq(("Alice", 85), ("Bob", 75), ("Charlie", 90), ("David", 80), ("Emily", 95)))
    
    // 输出结果
    rdd.foreach(println)
    
    // 关闭SparkContext对象
    sc.stop()
  }
}
